services/painting-surface-data-simulator-service/requirements.txt (1)

1-40: 의존성 버전 보안 검증 결과 및 개선 권고

• FastAPI
  • 현재: 0.110.0
  • PyPI 최신: 0.116.1 → 보안 패치가 포함된 최신 패치 라인(0.116.x)으로 업데이트 권장
• aiohttp
  • 현재: 3.9.1
  • PyPI 최신: 3.12.15 → 보안 패치가 포함된 최신 패치 라인(3.12.x)으로 업데이트 권장
• pip-audit 미설치
  • sandbox 환경에서 pip-audit가 없어 자동 취약점 검사가 실행되지 않았습니다.
  • 로컬 및 CI 환경에 pip install pip-audit 후 pip-audit 실행→보안 리포트 확인 필수

권장 조치

1. requirements.txt에서 FastAPI·aiohttp 버전을 최신 패치 라인으로 상향 조정
2. pip-audit 또는 GitHub Dependabot 같은 도구를 CI 파이프라인에 통합하여 주기적 보안 스캔 수행

위 개선 사항 적용 후 다시 검토 부탁드립니다.

services/painting-surface-defect-detection-model-service/tests/test_model_loader.py (1)

787-788: 파일 끝에 불필요한 빈 줄 제거 권장

파일 끝의 빈 줄을 제거하는 것이 좋습니다.

-if __name__ == "__main__":
-    pytest.main([__file__]) 
-
+if __name__ == "__main__":
+    pytest.main([__file__])

services/painting-surface-defect-detection-model-service/app/models/yolo_model.py (1)

110-123: 임계값 설정 파일 로드 시 FileNotFoundError 처리 누락

다른 로드 함수들과 달리 load_threshold_config에서는 FileNotFoundError를 명시적으로 처리하지 않습니다. 일관성을 위해 다른 함수들처럼 명시적으로 처리하는 것이 좋습니다.

 def load_threshold_config(self) -> Dict[str, float]:
     """임계값 설정 파일 로드"""
     try:
         threshold_filename = "thresholds.json"
         # 로컬 파일 경로 사용
         threshold_path = os.path.join(os.path.dirname(__file__), threshold_filename)
         
         with open(threshold_path, "r", encoding="utf-8") as f:
             thresholds = json.load(f)
         
         logger.info("Threshold configuration loaded successfully")
         return thresholds
         
+    except FileNotFoundError:
+        logger.warning(f"Threshold config file '{threshold_filename}' not found, using empty config")
+        return {}
     except Exception as e:
         logger.error(f"Failed to load threshold config: {str(e)}")
         return {}

services/painting-surface-defect-detection-model-service/app/routers/predict.py (1)

40-45: ImagePathRequest 모델이 정의되었지만 사용되지 않음

ImagePathRequest 모델이 정의되었지만 실제로 엔드포인트에서 사용되지 않습니다. 향후 사용 계획이 있다면 TODO 주석을 추가하거나, 사용하지 않을 예정이라면 제거하는 것이 좋습니다.

이미지 경로 기반 예측 엔드포인트를 구현하시겠습니까? 아니면 이 모델을 제거해야 할까요?

services/painting-surface-data-simulator-service/tests/run_tests.py (1)

46-54: Import 방식을 개선하여 static analysis 경고 해결

Static analysis 도구가 지적한 대로, pytest와 httpx 모듈을 import하지만 실제로는 사용하지 않습니다. 존재 여부 확인을 위해서는 importlib.util.find_spec를 사용하는 것이 더 적절합니다.

다음과 같이 개선하세요:

    # 테스트 의존성 설치 확인
    print("📦 테스트 의존성 확인 중...")
    try:
-        import pytest
-        import httpx
+        import importlib.util
+        if importlib.util.find_spec("pytest") is None:
+            raise ImportError("pytest")
+        if importlib.util.find_spec("httpx") is None:
+            raise ImportError("httpx")
        print("✅ 필요한 패키지가 설치되어 있습니다.")
    except ImportError as e:
        print(f"❌ 필요한 패키지가 설치되지 않았습니다: {e}")
        print("   다음 명령어로 설치하세요:")
        print("   pip install -r requirements-dev.txt")
        sys.exit(1)

services/painting-surface-data-simulator-service/app/config/settings.py (2)

1-2: 사용하지 않는 import 제거

Static analysis 도구가 지적한 대로 os와 typing.Dict 모듈이 import되었지만 실제로 사용되지 않습니다.

사용하지 않는 import를 제거하세요:

-import os
-from typing import Dict
from pydantic_settings import BaseSettings

---

30-33: 불필요한 property 메서드

model_service_url property가 단순히 painting_model_url 값을 반환하기만 합니다. 추가적인 로직이 없다면 직접 painting_model_url 필드를 사용하는 것이 더 간단합니다.

Property를 제거하고 직접 필드를 사용하거나, 향후 확장성을 위해 유지할지 결정하세요:

-    @property
-    def model_service_url(self) -> str:
-        """도장 표면 결함 감지 모델 서비스 URL"""
-        return self.painting_model_url

다른 코드에서 settings.model_service_url 대신 settings.painting_model_url을 직접 사용하세요.

services/painting-surface-data-simulator-service/README.md (2)

16-31: 코드 블록에 언어 지정 추가

Markdown 린터가 지적한 대로 fenced code block에 언어를 지정하면 가독성이 향상됩니다.

아키텍처 다이어그램과 디렉토리 구조에 적절한 언어 식별자를 추가하세요:

-```
+```text
┌─────────────────┐    ┌──────────────────┐    ┌─────────────────┐
│   Azure Blob    │    │   Simulator      │    │   Painting      │
│   Storage       │◄──►│   Service        │◄──►│   Surface       │
│   (Images)      │    │   (Port 8012)    │    │   Model         │
│                 │    │                  │    │   (Port 8002)   │
└─────────────────┘    └──────────────────┘    └─────────────────┘
                               │
                               ▼
                        ┌──────────────────┐
                        │   Logger         │
                        │   (JSON Files)   │
                        │   - logs/        │
                        │   - errors/      │
                        └──────────────────┘

---

341-345: 디렉토리 구조 코드 블록에 언어 지정

Line 341의 로그 파일 구조에도 언어 식별자를 추가하세요.

-```
+```text
logs/
├── painting_defect_detections.json    # 결함 탐지 결과 로그
└── painting_errors.json               # 에러 로그

services/painting-surface-data-simulator-service/app/services/azure_storage.py (1)

1-4: 사용하지 않는 import 제거 필요

typing.Any, asyncio, azure.core.exceptions.AzureError는 실제로 사용되지 않으므로 제거해야 합니다.

-from typing import List, Dict, Any, Optional
+from typing import List, Dict, Optional
-import asyncio
 from azure.storage.blob.aio import BlobServiceClient
-from azure.core.exceptions import AzureError, ClientAuthenticationError
+from azure.core.exceptions import ClientAuthenticationError

services/painting-surface-data-simulator-service/tests/test_settings.py (1)

1-3: 사용하지 않는 import 제거 필요

pytest는 실제로 사용되지 않으므로 제거해야 합니다.

-import pytest
 import os
 from app.config.settings import Settings

services/painting-surface-data-simulator-service/tests/test_azure_storage.py (1)

1-5: 사용하지 않는 import 제거 필요

asyncio와 azure.core.exceptions.AzureError는 실제로 사용되지 않으므로 제거해야 합니다.

 import pytest
-import asyncio
 from unittest.mock import AsyncMock, MagicMock, patch
-from azure.core.exceptions import AzureError, ClientAuthenticationError
+from azure.core.exceptions import ClientAuthenticationError
 from app.services.azure_storage import AzureStorageService

services/painting-surface-data-simulator-service/app/routers/test_connection_router.py (2)

4-5: 사용하지 않는 import 제거 필요

settings는 실제로 사용되지 않고, pytest는 라우터 파일에서 필요하지 않습니다.

 from fastapi import APIRouter
 from app.services.model_client import painting_surface_model_client
 from app.services.azure_storage import azure_storage
-from app.config.settings import settings
-import pytest

---

16-18: Azure Storage 연결 상태 관리 개선 필요

매번 연결하고 끊는 대신, 이미 연결된 상태를 확인하는 것이 효율적일 수 있습니다. 또한 연결이 이미 되어 있는 경우 중복 연결을 피해야 합니다.

     try:
-        await azure_storage.connect()
+        if not azure_storage.client:
+            await azure_storage.connect()
         files = await azure_storage.list_data_files()
-        await azure_storage.disconnect()
+        # 테스트 목적이므로 연결을 끊지 않음 (애플리케이션 수명 주기 동안 유지)

services/painting-surface-data-simulator-service/tests/test_scheduler_service.py (3)

1-5: 사용하지 않는 import 제거 필요

datetime는 실제로 사용되지 않으므로 제거해야 합니다.

 import pytest
 import asyncio
 from unittest.mock import AsyncMock, MagicMock, patch
-from datetime import datetime
 from app.services.scheduler_service import SimulatorScheduler

---

19-21: 사용하지 않는 변수 제거

loop 변수가 할당되었지만 사용되지 않습니다.

             try:
-                loop = asyncio.get_running_loop()
+                asyncio.get_running_loop()
                 asyncio.create_task(self.scheduler.stop())

---

17-24: 비동기 작업 정리 로직 개선 필요

현재 teardown_method에서 실행 중인 이벤트 루프를 확인하고 있지만, pytest-asyncio를 사용하는 경우 더 안전한 방법이 있습니다.

     def teardown_method(self):
         """각 테스트 메서드 실행 후 정리"""
         if self.scheduler.is_running:
-            # 이벤트 루프가 실행 중일 때만 create_task 사용
-            try:
-                asyncio.get_running_loop()
-                asyncio.create_task(self.scheduler.stop())
-            except RuntimeError:
-                # 이벤트 루프가 실행 중이 아니면 무시
-                pass
+            # pytest-asyncio가 이벤트 루프를 관리하므로
+            # 동기적으로 정리 플래그만 설정
+            self.scheduler.is_running = False
+            if self.scheduler.scheduler:
+                self.scheduler.scheduler.shutdown(wait=False)

services/painting-surface-data-simulator-service/tests/test_logger.py (3)

1-5: 불필요한 import 정리 (Ruff F401).

pytest, tempfile, MagicMock가 사용되지 않습니다. 정리하면 테스트 가독성과 린트 통과에 도움이 됩니다.

다음과 같이 정리하세요:

-import pytest
 import os
 import json
-import tempfile
 from unittest.mock import patch, MagicMock
+from unittest.mock import patch

---

83-89: 콘솔 출력 검증을 더 엄격하게.

현재는 print가 호출됐는지만 확인합니다. 예상 메시지까지 검증하면 회귀를 더 잘 잡을 수 있습니다.

다음 단언을 추가하세요:

 with patch('builtins.print') as mock_print:
     logger.log_normal_processing(service_name, prediction_result)
     
-    # 콘솔 출력 확인
-    mock_print.assert_called()
+    # 콘솔 출력 확인(예상 메시지)
+    mock_print.assert_any_call(
+        f"✅ NORMAL: {service_name} - 결함 없음 (총 {prediction_result.get('total_count', 'N/A')}개 이미지)"
+    )

---

14-17: tmp_path 활용 제안(테스트 격리성 개선).

고정 디렉터리명("test-logs") 대신 pytest의 tmp_path를 사용하면 테스트 간 충돌 가능성을 줄일 수 있습니다.

원한다면 setup/teardown 대신 테스트마다 tmp_path로 디렉터리를 생성해 settings 패치를 구성하도록 리팩터링해 드릴 수 있습니다.

services/painting-surface-data-simulator-service/tests/test_model_client.py (1)

2-4: 불필요한 import 정리 (Ruff F401).

asyncio, httpx가 이 파일 내에서 직접 사용되지 않습니다(모킹은 문자열 경로 패치로 충분). 제거하세요.

-import asyncio
 from unittest.mock import AsyncMock, MagicMock, patch
-import httpx

services/painting-surface-data-simulator-service/app/main.py (3)

8-8: 사용되지 않는 import 제거 (Ruff F401).

painting_surface_model_client를 가져오지만 사용하지 않습니다. 제거하세요.

-from app.services.model_client import painting_surface_model_client

---

44-44: 불필요한 f-string 접두사 제거 (Ruff F541).

문자열에 보간 변수가 없어 f 접두사를 제거하세요.

-    print(f"🎯 대상 서비스: 도장 표면 결함탐지 모델")
+    print("🎯 대상 서비스: 도장 표면 결함탐지 모델")

---

54-67: 전역 싱글톤 의존성 대신 DI로 전환 권장.

main에서 전역 서비스(azure_storage, simulator_scheduler)를 직접 임포트/사용하고 있습니다. 이전 학습(Learnings)에 따라 FastAPI DI 패턴(app.dependencies에서 setter/getter 제공, 라우터에서 Depends로 주입)으로 전환하면 테스트 용이성과 유지보수성이 개선됩니다.

해당 리팩터를 고려하실까요? 필요하면 기존 simulator_router와 main에 맞춘 DI 초안 패치를 제안드리겠습니다.

services/painting-surface-data-simulator-service/tests/test_simulator_router.py (2)

4-9: 불필요한 import 정리 (Ruff F401).

사용되지 않는 MagicMock, TestClient, simulator_scheduler, painting_surface_model_client를 제거하세요.

-from unittest.mock import AsyncMock, MagicMock, patch
-from fastapi.testclient import TestClient
+from unittest.mock import AsyncMock, patch
 from fastapi import HTTPException
-from app.routers.simulator_router import get_simulator_status, start_simulator, stop_simulator, get_recent_logs
-from app.services.scheduler_service import simulator_scheduler
-from app.services.model_client import painting_surface_model_client
+from app.routers.simulator_router import get_simulator_status, start_simulator, stop_simulator, get_recent_logs

---

216-223: 중첩 with를 단일 with로 합치기 (SIM117).

컨텍스트 매니저를 하나로 합치면 더 간결하고 파이썬 스타일 가이드에 부합합니다.

-        with patch('os.path.exists', return_value=True):
-            with patch('builtins.open', side_effect=PermissionError("Permission denied")):
-                # 로그 조회 시도 (예외 발생)
-                with pytest.raises(HTTPException) as exc_info:
-                    await get_recent_logs()
+        with patch('os.path.exists', return_value=True), \
+             patch('builtins.open', side_effect=PermissionError("Permission denied")):
+            # 로그 조회 시도 (예외 발생)
+            with pytest.raises(HTTPException) as exc_info:
+                await get_recent_logs()

services/painting-surface-data-simulator-service/tests/conftest.py (2)

19-25: 중복 asyncio 마커 적용 가능성.

파일 상단의 pytest_collection_modifyitems에서 코루틴을 자동으로 asyncio 마킹합니다. 개별 테스트에서도 @pytest.mark.asyncio를 사용하므로 중복입니다. 한 곳으로 일원화하는 것을 권장합니다.

원하시면 컬렉션 훅을 제거하고 테스트 파일의 명시적 마커만 유지하도록 변경하는 패치를 드리겠습니다.

---

35-52: Settings 모킹 일관성 확인.

mock.model_service_url과 painting_model_url 모두 설정되어 있습니다. app/config/settings.py의 model_service_url 프로퍼티가 painting_model_url을 반환하므로 둘 중 하나만으로도 충분합니다. 한쪽으로 정리하면 혼동을 줄일 수 있습니다.

-    mock.painting_model_url = "http://test-model:8002"
-    mock.model_service_url = "http://test-model:8002"  # 프로퍼티 추가
+    mock.painting_model_url = "http://test-model:8002"

또는 반대로 model_service_url만 사용하도록 테스트/클라이언트 초기화 경로를 통일하세요.

services/painting-surface-data-simulator-service/tests/test_main.py (3)

2-3: 사용하지 않는 import 제거

asyncio와 MagicMock이 import되었지만 사용되지 않습니다.

-import asyncio
-from unittest.mock import AsyncMock, MagicMock, patch
+from unittest.mock import AsyncMock, patch

---

38-44: 테스트 응답 코드 검증 개선 필요

시뮬레이터 라우터 테스트에서 여러 상태 코드를 허용하는 것은 테스트의 명확성을 떨어뜨립니다.

 def test_simulator_router_included(self):
     """시뮬레이터 라우터 포함 여부 테스트"""
     response = self.client.get("/simulator/status")
     
-    # 라우터가 포함되어 있다면 200 또는 적절한 응답을 받아야 함
-    # 실제 구현에 따라 응답이 달라질 수 있음
-    assert response.status_code in [200, 404, 500]
+    # 라우터가 포함되어 있다면 200 응답을 받아야 함
+    assert response.status_code == 200

---

46-52: 테스트 응답 코드 검증 개선 필요

테스트 연결 라우터 테스트에서도 명확한 예상 응답 코드를 지정해야 합니다.

 def test_test_connection_router_included(self):
     """테스트 연결 라우터 포함 여부 테스트"""
     response = self.client.post("/test/azure-storage-connection")
     
-    # 라우터가 포함되어 있다면 적절한 응답을 받아야 함
-    # 실제 구현에 따라 응답이 달라질 수 있음
-    assert response.status_code in [200, 404, 500]
+    # Azure 연결이 설정되지 않은 경우 500 응답 예상
+    assert response.status_code == 500

services/painting-surface-data-simulator-service/app/services/scheduler_service.py (2)

44-44: 불필요한 f-string 접두사 제거

플레이스홀더가 없는 문자열에 f-string 접두사가 사용되었습니다.

-    print(f"📊 대상 서비스: 도장 표면 결함탐지 모델")
+    print("📊 대상 서비스: 도장 표면 결함탐지 모델")

---

73-73: 불필요한 f-string 접두사 제거

플레이스홀더가 없는 문자열에 f-string 접두사가 사용되었습니다.

-    print(f"📈 활성 서비스: 1/1")
+    print("📈 활성 서비스: 1/1")

services/painting-surface-data-simulator-service/app/services/model_client.py (5)

5-5: 사용하지 않는 import 제거

datetime이 import되었지만 사용되지 않습니다.

-from datetime import datetime

---

20-20: 불필요한 f-string 접두사 제거

플레이스홀더가 없는 문자열에 f-string 접두사가 사용되었습니다.

-    print(f"❌ Painting Surface 서비스 URL을 찾을 수 없습니다.")
+    print("❌ Painting Surface 서비스 URL을 찾을 수 없습니다.")

---

29-29: 불필요한 f-string 접두사 제거

플레이스홀더가 없는 문자열에 f-string 접두사가 사용되었습니다.

-    print(f"🎨 도장 표면 이미지 예측 요청...")
+    print("🎨 도장 표면 이미지 예측 요청...")

---

76-79: 조건부 할당 간소화

if-else 블록을 삼항 연산자로 간소화할 수 있습니다.

-    if defect_count > 0:
-        final_status = "anomaly"
-    else:
-        final_status = "normal"
+    final_status = "anomaly" if defect_count > 0 else "normal"

---

165-165: 불필요한 f-string 접두사 제거

플레이스홀더가 없는 문자열에 f-string 접두사가 사용되었습니다.

-    print(f"   ✅ 결함 없음 - 정상 상태")
+    print("   ✅ 결함 없음 - 정상 상태")

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

Learnt from: doyooon
PR: smart-factory-team/smart_FAST#30
File: services/painting-surface-defect-detection-model-service/app/main.py:8-26
Timestamp: 2025-08-08T07:44:19.852Z
Learning: For the painting surface defect service, avoid using global variables for dependency sharing between main and routers. Prefer FastAPI DI with a dedicated app.dependencies module exposing set_detection_service()/get_detection_service(), and inject the service via Depends in router endpoints.

services/painting-surface-data-simulator-service/tests/test_scheduler_service.py (1)

39-41: Indentation issues from earlier review are fixed — thanks

The misindented comments noted previously are now aligned with surrounding code blocks.

Also applies to: 66-68

services/painting-surface-data-simulator-service/app/services/model_client.py (1)

100-101: Avoid bare except in health_check to prevent swallowing critical errors

Catching all exceptions hides unexpected failures. Catch httpx-specific exceptions instead.

-        except:
-            return False
+        except (httpx.HTTPError, httpx.ConnectError, httpx.TimeoutException):
+            return False

services/painting-surface-data-simulator-service/app/services/azure_storage.py (1)

30-33: Do not print connection string fragments — secrets exposure risk

Printing even partial connection strings can leak credentials. Replace with a generic message.

         except ClientAuthenticationError as e:
             print(f"❌ Azure Storage 인증 실패: {e}")
-            print(f"   연결 문자열을 확인해주세요: {self.connection_string[:50]}...")
+            print("   연결 문자열을 확인해주세요.")
             raise

services/painting-surface-data-simulator-service/requirements.txt (1)

15-16: httpx dependency already specified - remove duplicate.

The previous review comment correctly identified that httpx is defined twice in this file. Line 16 has httpx==0.25.2 (which appears to be missing from the current code but was in the previous version), and Line 22 has httpx>=0.24.0. This duplication should be resolved.

services/painting-surface-data-simulator-service/tests/test_scheduler_service.py (1)

4-4: Remove unused import to satisfy linter

datetime is imported but never used.

-from datetime import datetime

services/painting-surface-data-simulator-service/app/services/model_client.py (3)

5-5: Remove unused import

datetime is not used in this module.

-from datetime import datetime

---

20-21: Drop unnecessary f-strings without placeholders

These f-strings have no interpolations; remove the f prefix.

-            print(f"❌ Painting Surface 서비스 URL을 찾을 수 없습니다.")
+            print("❌ Painting Surface 서비스 URL을 찾을 수 없습니다.")
@@
-        print(f"🎨 도장 표면 이미지 예측 요청...")
+        print("🎨 도장 표면 이미지 예측 요청...")
@@
-            print(f"   ✅ 결함 없음 - 정상 상태")
+            print("   ✅ 결함 없음 - 정상 상태")

Also applies to: 29-29, 164-164

---

76-80: Simplify conditional assignment

Use a ternary operator for brevity.

-        if defect_count > 0:
-            final_status = "anomaly"
-        else:
-            final_status = "normal"
+        final_status = "anomaly" if defect_count > 0 else "normal"

services/painting-surface-data-simulator-service/app/services/azure_storage.py (2)

1-5: Remove unused imports (lint: F401)

Drop Any, asyncio, and AzureError which are not used.

-from typing import List, Dict, Any, Optional
-import asyncio
+from typing import List, Dict, Optional
 from azure.storage.blob.aio import BlobServiceClient
-from azure.core.exceptions import AzureError, ClientAuthenticationError
+from azure.core.exceptions import ClientAuthenticationError

---

136-144: Batching should wrap to maintain consistent batch_size across cycles

Current slicing truncates at list end, yielding fewer items than batch_size. Use modular indexing to wrap.

-            batch_size = min(settings.batch_size, len(image_files))
-            start_idx = self.image_index % len(image_files)
-            end_idx = min(start_idx + batch_size, len(image_files))
-            
-            batch_files = image_files[start_idx:end_idx]
-            self.image_index = (self.image_index + batch_size) % len(image_files)
+            batch_size = min(settings.batch_size, len(image_files))
+            start_idx = self.image_index % len(image_files)
+            batch_files = [
+                image_files[(start_idx + i) % len(image_files)]
+                for i in range(batch_size)
+            ]
+            self.image_index = (self.image_index + batch_size) % len(image_files)

services/painting-surface-data-simulator-service/requirements.txt (4)

21-22: Consider pinning httpx version for production consistency.

While the flexible version constraint httpx>=0.24.0 allows for updates, pinning to a specific version (e.g., httpx==0.25.2) would ensure reproducible builds and avoid potential compatibility issues in production deployments.

-# HTTP 테스트 클라이언트
-httpx>=0.24.0
+# HTTP 테스트 클라이언트
+httpx==0.25.2

---

16-19: Consider consistent versioning strategy across test dependencies.

The testing dependencies mix pinned versions (pytest==7.4.3, pytest-asyncio==0.21.1) with flexible constraints (pytest-cov>=4.1.0, pytest-mock>=3.11.0). For better reproducibility, consider using consistent versioning strategy.

---

34-34: Missing newline at end of file.

The file should end with a newline character for better POSIX compliance and to avoid potential issues with some tools.

 # 개발 도구
 pre-commit>=3.3.0
+

---

21-33: Consider using English comments for consistency.

The comments are written in Korean while the rest of the codebase appears to use English. Consider using English comments for better international collaboration and consistency.

-# HTTP 테스트 클라이언트
+# HTTP test client
 httpx>=0.24.0

-# 코드 품질 도구
+# Code quality tools
 black>=23.0.0
 flake8>=6.0.0
 mypy>=1.5.0

-# 테스트 커버리지
+# Test coverage
 coverage>=7.2.0

-# 개발 도구
+# Development tools
 pre-commit>=3.3.0

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

services/painting-surface-data-simulator-service/app/config/settings.py (1)

8-9: Add fail-fast validation for required AZURE_CONNECTION_STRING.

Make the error explicit and user-friendly when the env var is missing or blank.

 class Settings(BaseSettings):
     # Azure Storage 설정
     azure_connection_string: str
     azure_container_name: str = "simulator-data"
+
+    @field_validator("azure_connection_string")
+    @classmethod
+    def validate_azure_connection_string(cls, v: str) -> str:
+        if not v or not v.strip():
+            raise ValueError(
+                "AZURE_CONNECTION_STRING 환경 변수가 설정되지 않았습니다. "
+                ".env 파일 또는 실행 환경에서 Azure Storage 연결 문자열을 설정해주세요."
+            )
+        return v

services/painting-surface-data-simulator-service/tests/test_settings.py (1)

9-13: Fix test: set required env var before instantiating Settings.

Settings requires AZURE_CONNECTION_STRING; without it, instantiation will fail.

     def test_settings_default_values(self):
         """기본값 테스트"""
-        # 환경 변수가 설정되어 있으므로 기본값 확인 테스트
-        settings = Settings()
+        # 필수 환경 변수 설정 후 기본값 확인 테스트
+        os.environ['AZURE_CONNECTION_STRING'] = 'test_connection_string'
+        try:
+            settings = Settings()
+        finally:
+            if 'AZURE_CONNECTION_STRING' in os.environ:
+                del os.environ['AZURE_CONNECTION_STRING']

services/painting-surface-data-simulator-service/app/config/settings.py (1)

35-38: Use SettingsConfigDict for model_config (pydantic v2 idiomatic).

Be explicit with SettingsConfigDict to align with pydantic-settings v2 best practices.

-    model_config = {
-        "env_file": ".env",
-        "env_file_encoding": "utf-8"
-    }
+    model_config: SettingsConfigDict = SettingsConfigDict(
+        env_file=".env",
+        env_file_encoding="utf-8",
+    )

services/painting-surface-data-simulator-service/tests/test_settings.py (2)

1-1: Remove unused import (pytest).

Clean up unused import flagged by Ruff.

-import pytest

---

3-3: Heads-up: importing Settings triggers settings module import-time side effects.

If app/config/settings.py keeps a module-level instance (settings = Settings()), this import will fail unless AZURE_CONNECTION_STRING is set before the test module import. Prefer the lazy get_settings() approach or ensure env vars are set globally (e.g., in conftest with an autouse fixture).

services/painting-surface-data-simulator-service/tests/conftest.py (4)

4-5: Remove unused imports (sys, Path).

Clean up unused imports flagged by Ruff.

 import asyncio
 import os
-import sys
-from pathlib import Path

---

29-35: Consider using pytest-asyncio’s event loop fixture (session scope).

Custom function-scoped event loop can conflict with pytest-asyncio versions that expect a session-scoped loop. Prefer the plugin’s fixture or align scope with it.

Option:

-@pytest.fixture
-def event_loop():
-    """비동기 테스트를 위한 이벤트 루프 fixture"""
-    loop = asyncio.new_event_loop()
-    yield loop
-    loop.close()
+import pytest_asyncio
+
+@pytest_asyncio.fixture(scope="session")
+def event_loop():
+    """비동기 테스트를 위한 이벤트 루프 fixture (session scope)"""
+    loop = asyncio.new_event_loop()
+    yield loop
+    loop.close()

Verify pytest-asyncio version compatibility in your environment before applying.

---

65-68: Align mock simulate_painting_surface_data() shape with production code.

The real service returns images, total_images, batch_size, current_batch. The mock adds metadata and omits totals, which can mask mismatches.

     mock_storage.simulate_painting_surface_data = AsyncMock(return_value={
-        "images": ["test1.jpg", "test2.jpg"],
-        "metadata": {"source": "test"}
+        "images": ["test1.jpg", "test2.jpg"],
+        "total_images": 2,
+        "batch_size": 2,
+        "current_batch": ["test1.jpg", "test2.jpg"]
     })

---

76-81: Align mock model_client return with service contract.

Model client predict_painting_surface_data() in app/services/model_client.py returns a structure with images and combined. The mock returns status/defect_count/total_count, which may hide integration issues.

-    mock_client.predict_painting_surface_data = AsyncMock(return_value={
-        "status": "normal",
-        "defect_count": 0,
-        "total_count": 2
-    })
+    mock_client.predict_painting_surface_data = AsyncMock(return_value={
+        "images": [
+            {"file": "test1.jpg", "result": {"defect": False}},
+            {"file": "test2.jpg", "result": {"defect": False}},
+        ],
+        "combined": {"defect_count": 0, "total_count": 2}
+    })

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

services/painting-surface-data-simulator-service/app/main.py (1)

3-3: Prefer lazy, cached settings to avoid import-time failures

Importing a module-level settings instance can raise at import time if required env vars are missing. Switch to a get_settings() factory and call it in this module.

After implementing get_settings() in settings.py:

-from app.config.settings import settings
+from app.config.settings import get_settings
+settings = get_settings()

services/painting-surface-data-simulator-service/app/config/settings.py (2)

49-50: Avoid module-level instantiation; provide a cached factory

Prevents import-time failures and improves testability.

-settings = Settings()
+@lru_cache(maxsize=1)
+def get_settings() -> Settings:
+    """Lazy-load and cache Settings; avoids import-time side effects."""
+    return Settings()

Follow-up: update call sites to import get_settings and do settings = get_settings().

---

8-8: Validate required env var azure_connection_string

Fail fast with a clear message if missing or blank.

 class Settings(BaseSettings):
     # Azure Storage 설정
     azure_connection_string: str
+
+    @field_validator('azure_connection_string')
+    @classmethod
+    def validate_azure_connection_string(cls, v: str) -> str:
+        if not v or not v.strip():
+            raise ValueError(
+                "AZURE_CONNECTION_STRING 환경 변수가 설정되지 않았습니다. "
+                ".env 파일 또는 배포 환경에서 Azure Storage 연결 문자열을 설정해주세요."
+            )
+        return v

services/painting-surface-data-simulator-service/app/services/model_client.py (2)

98-104: Avoid bare except; handle httpx exceptions explicitly

Use explicit exceptions so real issues aren’t silenced.

-        except:
-            return False
+        except (httpx.HTTPError, httpx.ConnectError, httpx.TimeoutException):
+            return False

---

165-170: Guard confidence before using .3f to avoid TypeError

Formatting non-numeric values with :.3f will raise. Guard it.

-                print(f"        🎯 신뢰도: {pred.get('confidence', 'N/A'):.3f}")
+                confidence = pred.get('confidence')
+                if isinstance(confidence, (int, float)):
+                    print(f"        🎯 신뢰도: {confidence:.3f}")
+                else:
+                    print(f"        🎯 신뢰도: {confidence if confidence is not None else 'N/A'}")

services/painting-surface-data-simulator-service/app/main.py (2)

8-8: Remove unused import painting_surface_model_client

Imported but never used. Clean it up to satisfy Ruff (F401) and avoid confusion.

-from app.services.model_client import painting_surface_model_client

---

44-45: Drop unnecessary f-string prefix

These lines contain no placeholders; remove the f prefix to satisfy Ruff (F541).

-    print(f"🔧 스케줄러 간격: {settings.scheduler_interval_minutes}분")
-    print(f"🎯 대상 서비스: 도장 표면 결함탐지 모델")
+    print(f"🔧 스케줄러 간격: {settings.scheduler_interval_minutes}분")
+    print("🎯 대상 서비스: 도장 표면 결함탐지 모델")

Note: Only the second line needed the change; left the first intact since it has a placeholder.

services/painting-surface-data-simulator-service/app/services/scheduler_service.py (2)

43-46: Drop unnecessary f-strings without placeholders

Ruff (F541): remove f prefix where no formatting occurs.

-            print(f"📊 대상 서비스: 도장 표면 결함탐지 모델")
+            print("📊 대상 서비스: 도장 표면 결함탐지 모델")
@@
-        print(f"📈 활성 서비스: 1/1")
+        print("📈 활성 서비스: 1/1")

Also applies to: 73-75

---

28-36: Prevent overlapping job runs (coalesce and max_instances)

If a run takes longer than the interval, multiple instances may overlap depending on scheduler defaults. Make this explicit to avoid concurrent executions of the job.

             self.scheduler.add_job(
                 func=self._simulate_data_collection,
                 trigger=IntervalTrigger(
                     minutes=settings.scheduler_interval_minutes),
                 id='data_simulation',
                 name='Data Collection Simulation',
-                replace_existing=True
+                replace_existing=True,
+                max_instances=1,
+                coalesce=True,
+                misfire_grace_time=60
             )

services/painting-surface-data-simulator-service/app/config/settings.py (2)

1-4: Remove unused imports and add required ones (validator, config, cache)

os and Dict are unused. You’ll need field_validator, SettingsConfigDict, and lru_cache if adopting validation and lazy loading.

-import os
-from typing import Dict
-from pydantic_settings import BaseSettings
+from functools import lru_cache
+from pydantic import field_validator
+from pydantic_settings import BaseSettings, SettingsConfigDict

---

43-46: Use SettingsConfigDict and consider ignoring extra envs

Minor consistency/pydantic v2 idiom improvement.

-    model_config = {
-        "env_file": ".env",
-        "env_file_encoding": "utf-8"
-    }
+    model_config = SettingsConfigDict(
+        env_file=".env",
+        env_file_encoding="utf-8",
+        extra="ignore",
+    )

services/painting-surface-data-simulator-service/app/services/model_client.py (3)

5-5: Remove unused import datetime

Not used. Satisfies Ruff (F401).

-from datetime import datetime

---

21-22: Drop unnecessary f-string prefixes

Strings have no placeholders. Remove f to satisfy Ruff (F541).

-            print(f"❌ Backend 서비스 URL을 찾을 수 없습니다.")
+            print("❌ Backend 서비스 URL을 찾을 수 없습니다.")
@@
-        print(f"🎨 도장 표면 이미지 예측 요청...")
+        print("🎨 도장 표면 이미지 예측 요청...")
@@
-            print(f"   ✅ 결함 없음 - 정상 상태")
+            print("   ✅ 결함 없음 - 정상 상태")

Also applies to: 30-31, 171-171

---

4-4: Align with lazy settings (if adopted)

If you switch to get_settings(), update usages here to avoid import-time config capture.

-from app.config.settings import settings
+from app.config.settings import get_settings
+settings = get_settings()
@@
-        self.backend_url = settings.backend_service_url
+        self.backend_url = settings.backend_service_url

Note: If backend URL can change at runtime, consider resolving from settings per request instead of caching in init.

Also applies to: 16-16

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

💡 Knowledge Base configuration:

• MCP integration is disabled by default for public repositories
• Jira integration is disabled by default for public repositories
• Linear integration is disabled by default for public repositories

You can enable these sources in your CodeRabbit configuration.